//package com.consumer1.listener;
//
//import com.jobs.common.consts.RabbitCons;
//import com.jobs.common.vo.Letter;
//import com.rabbitmq.client.Channel;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.amqp.core.Message;
//import org.springframework.amqp.rabbit.annotation.RabbitHandler;
//import org.springframework.amqp.rabbit.annotation.RabbitListener;
//import org.springframework.stereotype.Component;
//
//import java.time.LocalDateTime;
//
///**
// * @author meng
// * 2020/09/22
// */
//@Component
//@Slf4j
//public class DelayMessageListener {
//
//    @RabbitListener(queues = {RabbitCons.DELAY_QUEUE})
//    @RabbitHandler
//    public void receiveMessage(Channel channel, Message message, Letter letter) {
//        System.out.println(message);
//        log.info("[listenerDelayQueue 监听的消息] - [消费时间] - [{}] - [{}]", LocalDateTime.now(), letter.toString());
//    }
//}